package com.freejava.test_rocketmq.service;

import com.freejava.test_rocketmq.entity.MyMessage;

/**
 * RocketMQ的工具接口
 *
 */
public interface BaseRocketMQTool {
    /**
     * 同步方式发送消息
     *
     * @param myMessage 消息实体类
     */
    void sendMsg(MyMessage myMessage);

    /**
     * 异步方式发送消息
     *
     * @param myMessage 消息实体类
     */
    void asyncSendMsg(MyMessage myMessage);
}
